package com.example.test.stream1;

import org.apache.kafka.streams.state.RocksDBConfigSetter;
import org.rocksdb.BlockBasedTableConfig;
import org.rocksdb.Options;

import java.util.Map;

/**
 * CustomRocksDBConfigSetter
 *
 * @author yongxiang
 * @date 2024/9/10 15:52
 * @desc
 */
public class CustomRocksDBConfigSetter implements RocksDBConfigSetter {
    @Override
    public void setConfig(String storeName, Options options, Map<String, Object> configs) {

    }

    @Override
    public void close(String storeName, Options options) {
        // Clean up resources if needed
        //System.out.println("close db");
    }
}